/*
package at.guigu.mq.listener;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
import java.time.LocalTime;
*/
/**
 * Work Queue工作队列模型消费者示例
 * 消费者消息监听处理---消费者1每秒处理50条消息，消费者2每秒处理10条消息
 *//*

@Component
public class SpringRabbitListener02 {
    // 指定监听的消息队列---被监听的队列的消息会自动传入被@RabbitListener注解修饰的方法中作为该方法的参数
    @RabbitListener(queues = "simple.queue")
    public void listenWorkQueueMessage01(String msg) throws InterruptedException {
        System.out.println("消费者1...接收到simple.queue的消息：【" + msg + "】" + " 时间：" + LocalTime.now());
        // 消费者1每秒处理50条消息
        Thread.sleep(20); // 暂时放弃对CPU的使用权，但不会释放锁。作用：让当前线程由可运行态转换为有时限的等待，超时时间到自动恢复为可运行状态
    }

    @RabbitListener(queues = "simple.queue")
    public void listenWorkQueueMessage02(String msg) throws InterruptedException {
        // 消费者2控制台红色打印
        System.err.println("消费者2...接收到simple.queue的消息：【" + msg + "】" + " 时间：" + LocalTime.now());
        // 消费者2每秒处理10条消息
        Thread.sleep(100); // 暂时放弃对CPU的使用权，但不会释放锁。作用：让当前线程由可运行态转换为有时限的等待，超时时间到自动恢复为可运行状态
    }

}*/
